package com.xyz.blockqueue;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;

public class EventQueue extends AbsQueue<QueueModel> {

    private static final Integer QUEUE_COUNT = 1000;
    private ArrayBlockingQueue<QueueModel> _queue = new ArrayBlockingQueue<>(QUEUE_COUNT);
    private static final EventQueue _instance = new EventQueue();

    public EventQueue(){

    }

    public static EventQueue getInstance(){
        return _instance;
    }

    @Override
    public BlockingQueue<QueueModel> getQueue() {
        return _queue;
    }

}
